package com.zdft.promotion.rabbitmq.service.api;

import com.zdft.promotion.rabbitmq.domain.QueueEnum;
import com.zdft.promotion.rabbitmq.model.PushModel;

import java.util.List;

public interface IMesssageService {

    void addOrderMessageToQueue(PushModel model, QueueEnum queueEnum);

    void addOrderMessageToQueue(List<PushModel> modelList, QueueEnum queueEnum);

    /**
     * 100 入库 200 出库 300 移仓调拨  301-商品明细 302-商品批次 303-缺货记录 ...
     * 详见@{@link com.zdft.promotion.common.constant.AysnPushConstant}
     * @param model
     * @return
     * @throws InterruptedException
     */
    boolean messageConsumer(PushModel model) throws InterruptedException;
}
